hub / github.com/cloudera/flume

github.com/cloudera/flume @cdh4.3.1-release

Chat with this repo

repository ↗ · DeepWiki ↗ · release cdh4.3.1-release ↗ · + Follow

4,845 symbols 22,464 edges 550 files ⚖ Apache-2.0 1,939 documented · 40% ● updated 5y ago★ 942

Browse by type

⨍ Functions 4,174◇ Types & classes 671

What it actually does AI analysis from the code graph — generated when you open this

loading…

Extension points exported contracts — how you extend this code

ExampleData (Interface)

This contains names for data files commited in the test directory for use with unit testing [11 implementers]

flume-core/src/test/java/com/cloudera/flume/ExampleData.java

EventSource (Interface)

This provides a synchronous interface to getting events. An state/event-based architecture will likely be more efficient [12 …

flume-core/src/main/java/com/cloudera/flume/core/EventSource.java

Reportable (Interface)

Any statistics presenting element will implement this interface. These should be registered to the ReporterManager so th [52 …

flume-core/src/main/java/com/cloudera/flume/reporter/Reportable.java

RollTrigger (Interface)

A trigger is a condition for controlling when rolling happens in a RollSink. The original default only allowed for time [6 …

flume-core/src/main/java/com/cloudera/flume/handlers/rolling/RollTrigger.java

Tagger (Interface)

A tagger is a mechanism that creates unique names for groups of events and adds annotation data to events. It keeps some [7 …

flume-core/src/main/java/com/cloudera/flume/handlers/rolling/Tagger.java

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 227 filesEventSink

This is a consumer of events from some source. Implementations of this interface must have a constructor with no arguments and …

flume-core/src/main/java/com/cloudera/flume/core/EventSink.java

↓ 129 filesFlumeConfiguration

This is the configuration file for flume. It uses hadoop's xml schema for properties. The default configuration is in …

flume-core/src/main/java/com/cloudera/flume/conf/FlumeConfiguration.java

↓ 117 filesReportable

Any statistics presenting element will implement this interface. These should be registered to the ReporterManager so that they …

flume-core/src/main/java/com/cloudera/flume/reporter/Reportable.java

↓ 116 filesClock

This is a singleton class that wraps time functions so that they can be mock'ed out later for testing. Users are expected to only …

flume-core/src/main/java/com/cloudera/util/Clock.java

↓ 84 filesReportEvent

Reports are just events that have some helpers for quickly outputting data in human readable or machine parseable formats. For …

flume-core/src/main/java/com/cloudera/flume/reporter/ReportEvent.java

↓ 76 filesAckListener

This is a interface decouple event-stream extracted notifications from the actions that are triggered by them. This explicitly …

flume-core/src/main/java/com/cloudera/flume/handlers/endtoend/AckListener.java

browse all functions →

Shape

Method 4,172

Class 622

Interface 32

Enum 17

Function 2

Languages

Java100%

C++1%

Python1%

Modules by API surface

flume-core/src/main/java/com/cloudera/flume/conf/FlumeConfiguration.java91 symbols

flume-core/src/main/java/com/cloudera/flume/agent/durability/NaiveFileWALManager.java52 symbols

flume-core/src/test/java/com/cloudera/flume/collector/TestCollectorSink.java36 symbols

flume-core/src/main/java/com/cloudera/flume/conf/FlumeBuilder.java34 symbols

flume-core/src/main/java/com/cloudera/flume/agent/diskfailover/NaiveFileFailoverManager.java34 symbols

flume-core/src/main/java/com/cloudera/flume/agent/FlumeNode.java34 symbols

flume-core/src/main/java/com/cloudera/flume/master/flows/FlowConfigManager.java33 symbols

flume-core/src/main/java/com/cloudera/distributed/GossipMulticast.java32 symbols

flume-core/src/main/java/com/cloudera/flume/master/ZooKeeperConfigStore.java31 symbols

flume-core/src/main/java/com/cloudera/flume/master/ConfigManager.java30 symbols

flume-core/src/main/java/com/cloudera/util/InternalHttpServer.java29 symbols

flume-core/src/main/java/com/cloudera/flume/util/FlumeShell.java29 symbols

For agents

$ claude mcp add flume \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/cloudera/flume @cdh4.3.1-release

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

For agents

Ask about this repo answers extend the page