hub / github.com/TALKDATA/JavaBigData

github.com/TALKDATA/JavaBigData @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

1,155 symbols 4,418 edges 128 files 177 documented · 15%

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

Builder (Interface)

Knows how to build FailurePolicys. Implementers must provide a no-arg constructor. [7 implementers]

code/flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/policy/FailurePolicy.java

Builder (Interface)

Knows how to build EntityParsers. Implementers must provide a no-arg constructor. @param The type of entiti [7 implementers]

code/flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/parser/EntityParser.java

Builder (Interface)

Knows how to construct this output formatter. Note: Implementations MUST provide a public a no-arg constructor.< [7 implementers]

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/SequenceFileSerializer.java

AsyncHbaseEventSerializer (Interface)

Interface for an event serializer which serializes the headers and body of an event to write them to hbase. This is conf [6 …

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHbaseEventSerializer.java

HbaseEventSerializer (Interface)

Interface for an event serializer which serializes the headers and body of an event to write them to hbase. This is conf [6 …

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HbaseEventSerializer.java

Core symbols most depended-on inside this repo

get

called by 171

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/RoundRobinList.java

called by 66

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSWriter.java

size

called by 58

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/RoundRobinList.java

stop

called by 54

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandler.java

process

called by 47

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandler.java

called by 43

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HbaseEventSerializer.java

build

called by 39

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/SequenceFileSerializer.java

toString

called by 36

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java

Shape

Method 982

Class 150

Interface 21

Enum 2

Languages

Java100%

Modules by API surface

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/FlumeHttpServletRequestWrapper.java56 symbols

code/flume-ng-sinks/flume-dataset-sink/src/test/java/org/apache/flume/sink/kite/TestDatasetSink.java41 symbols

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java40 symbols

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/TestHDFSEventSink.java37 symbols

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchSink.java32 symbols

code/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java28 symbols

code/flume-ng-sinks/flume-irc-sink/src/main/java/org/apache/flume/sink/irc/IRCSink.java26 symbols

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java26 symbols

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java25 symbols

code/flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java24 symbols

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineInterceptor.java23 symbols

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/TestBucketWriter.java23 symbols

Datastores touched

(mysql)Database · 1 repos

metastoreDatabase · 1 repos

For agents

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

⬇ download graph artifact