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% ● updated 4y ago★ 4603 open issues

Browse by type

⨍ Functions 982◇ Types & classes 173

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

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

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 46 filesRoundRobinList

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

↓ 32 filesHDFSWriter

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

↓ 22 filesBuilder

Knows how to construct this output formatter. Note: Implementations MUST provide a public a no-arg constructor.

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

↓ 20 filesMorphlineHandler

Interface to load Flume events into Solr

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

↓ 18 filesHiveEventSerializer

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java

↓ 14 filesHbaseEventSerializer

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

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

browse all functions →

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

github.com/TALKDATA/JavaBigData @main

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

Datastores touched

For agents

Ask about this repo answers extend the page