MCPcopy Index your code
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 1,939 documented · 40%
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

Core symbols most depended-on inside this repo

size
called by 384
flume-core/src/main/java/com/cloudera/util/Histogram.java
append
called by 370
flume-core/src/main/java/com/cloudera/flume/core/EventSink.java
get
called by 358
flume-core/src/main/java/com/cloudera/flume/core/Event.java
close
called by 344
flume-core/src/main/java/com/cloudera/flume/core/EventSink.java
get
called by 341
flume-core/src/main/java/com/cloudera/flume/conf/FlumeConfiguration.java
getSpecMan
called by 312
flume-core/src/main/java/com/cloudera/flume/master/FlumeMaster.java
add
called by 281
flume-core/src/main/java/com/cloudera/flume/core/FanOutSink.java
open
called by 238
flume-core/src/main/java/com/cloudera/flume/core/EventSink.java

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

Ask about this repo answers extend the page