Types & classes — github.com/TALKDATA/JavaBigData

hub / github.com/TALKDATA/JavaBigData / types & classes

Types & classes173 in github.com/TALKDATA/JavaBigData

⨍ Functions 982◇ Types & classes 173

ClassAbstractElasticSearchIndexRequestBuilderFactory

Abstract base class for custom implementations of {@link ElasticSearchIndexRequestBuilderFactory}.

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchIndexRequestBuilderFactory.java:39

ClassAbstractElasticSearchSinkTest

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchSinkTest.java:54

ClassAbstractHDFSWriter

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/AbstractHDFSWriter.java:36

ClassAsyncHBaseSink

A simple sink which reads events from a channel and writes them to HBase. This Sink uses an asynchronous API internally and is likely to perform bette

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java:102

InterfaceAsyncHbaseEventSerializer

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

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

ClassAvroEventSerializer

This class serializes Flume {@linkplain org.apache.flume.Event events} into Avro data files. The Flume event body is read as an Avro datum, and is

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/AvroEventSerializer.java:70

ClassAvroParser

An {@link EntityParser} that parses Avro serialized bytes from an event. The Avro schema used to serialize the data should be set as either a URL or

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

InterfaceBatchAware

This interface allows for implementing HBase serializers that are aware of batching. {@link #onBatchStart()} is called at the beginning of each batch

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/BatchAware.java:26

ClassBlobDeserializer

A deserializer that reads a Binary Large Object (BLOB) per event, typically one BLOB per file; To be used in conjunction with Flume SpoolDirectorySour

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java:43

ClassBlobHandler

BlobHandler for HTTPSource that returns event that contains the request parameters as well as the Binary Large Object (BLOB) uploaded with this reques

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobHandler.java:52

ClassBucketClosedException

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketClosedException.java:23

ClassBucketWriter

Internal API intended for HDFSSink use. This class does file rolling and handles file formats and serialization. Only the public methods in this class

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java:58

ClassBuilder

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

ClassBuilder

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

ClassBuilder

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

ClassBuilder

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/MyCustomSerializer.java:49

ClassBuilder

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/AvroEventSerializer.java:200

ClassBuilder

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSTextSerializer.java:70

ClassBuilder

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSWritableSerializer.java:68

ClassBuilder

Builder implementations MUST have a public no-arg constructor

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java:153

ClassBuilder

Builder implementations MUST have a public no-arg constructor

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

ClassBuilder

Builder implementations MUST have a public no-arg constructor

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/UUIDInterceptor.java:96

InterfaceBuilder

Knows how to build {@code FailurePolicy}s. Implementers must provide a no-arg constructor.

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

InterfaceBuilder

Knows how to build {@code EntityParser}s. Implementers must provide a no-arg constructor. @param <E> The type of entities generated

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

InterfaceBuilder

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:43

InterfaceCallRunner

Simple interface whose <tt>call</tt> method is called by {#callWithTimeout} in a new thread inside a {@linkplain java.security.PrivilegedExceptionActi

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java:470

InterfaceCallRunner

Simple interface whose <tt>call</tt> method is called by {#callWithTimeout} in a new thread inside a {@linkplain java.security.PrivilegedExceptionActi

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java:713

InterfaceCallRunner1

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java:474

ClassCellIdentifier

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java:676

ClassCoalesceValidator

For testing that the rows coalesced, serialized by {@link IncrementHBaseSerializer}, are of the expected batch size.

code/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java:668

ClassCollector

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

ClassCommitException

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java:490

ClassConfig

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/Config.java:21

ClassConnectException

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java:496

ClassContentBuilderUtil

Utility methods for using ElasticSearch {@link XContentBuilder}

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ContentBuilderUtil.java:34

ClassCustomElasticSearchIndexRequestBuilderFactory

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchSink.java:373

ClassDatasetSink

Sink that writes events to a Kite Dataset. This sink will parse the body of each incoming event and store the resulting entity in a Kite Dataset. It d

code/flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/DatasetSink.java:72

ClassDatasetSinkConstants

code/flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/DatasetSinkConstants.java:23

InterfaceDebugIncrementsCallback

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java:553

ClassDumbIRCServer

code/flume-ng-sinks/flume-irc-sink/src/test/java/org/apache/flume/sink/irc/TestIRCSink.java:109

InterfaceElasticSearchClient

Interface for an ElasticSearch client which is responsible for sending bulks of events to ElasticSearch.

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClient.java:29

ClassElasticSearchClientFactory

Internal ElasticSearch client factory. Responsible for creating instance of ElasticSearch clients.

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClientFactory.java:28

ClassElasticSearchDynamicSerializer

Basic serializer that serializes the event body and header fields into individual fields A best effort will be used to determine the content-type

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchDynamicSerializer.java:38

InterfaceElasticSearchEventSerializer

Interface for an event serializer which serializes the headers and body of an event to write them to ElasticSearch. This is configurable, so any confi

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchEventSerializer.java:34

InterfaceElasticSearchIndexRequestBuilderFactory

Interface for creating ElasticSearch {@link IndexRequestBuilder} instances from serialized flume events. This is configurable, so any config params re

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchIndexRequestBuilderFactory.java:36

ClassElasticSearchLogStashEventSerializer

Serialize flume events into the same format LogStash uses This can be used to send events to ElasticSearch and use clients such as Kabana which e

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchLogStashEventSerializer.java:73

ClassElasticSearchRestClient

Rest ElasticSearch client which is responsible for sending bulks of events to ElasticSearch using ElasticSearch HTTP API. This is configurable, so any

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchRestClient.java:48

ClassElasticSearchSink

A sink which reads events from a channel and writes them to ElasticSearch based on the work done by https://github.com/Aconex/elasticflume.git. T

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java:86

ClassElasticSearchSinkConstants

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSinkConstants.java:21

ClassElasticSearchTransportClient

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchTransportClient.java:46

ClassEmbeddedSource

code/flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/EmbeddedSource.java:27

InterfaceEntityParser

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

ClassEntityParserFactory

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

ClassEventSerializerIndexRequestBuilderFactory

Default implementation of {@link ElasticSearchIndexRequestBuilderFactory}. It serializes flume events using the {@link ElasticSearchEventSerializer} i

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/EventSerializerIndexRequestBuilderFactory.java:35

ClassFailure

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java:478

ClassFailureCallback

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java:623

InterfaceFailurePolicy

A policy for dealing with non-recoverable event delivery failures. Non-recoverable event delivery failures include: 1. Error parsing the event body

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

ClassFailurePolicyFactory

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

ClassFakeConfigurable

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchSink.java:446

ClassFakeEventSerializer

Internal class. Fake event serializer used for tests

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchSink.java:457

ClassFakeEventSerializer

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchIndexRequestBuilderFactory.java:191

ClassFakeIndexNameBuilder

Internal class. Fake index name builder used only for tests.

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchSink.java:484

ClassFlumeHttpServletRequestWrapper

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

ClassHBaseSink

A simple sink which reads events from a channel and writes them to HBase. The Hbase configuration is picked up from the first <tt>hbase-site.xml</tt>

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java:92

ClassHBaseSinkConfigurationConstants

Constants used for configuration of HBaseSink and AsyncHBaseSink

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSinkConfigurationConstants.java:27

ClassHDFSBadDataStream

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/HDFSBadDataStream.java:25

ClassHDFSBadSeqWriter

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/HDFSBadDataStream.java:26

ClassHDFSCompressedDataStream

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java:40

ClassHDFSDataStream

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java:38

ClassHDFSEventSink

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java:61

ClassHDFSSequenceFile

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java:35

ClassHDFSTestSeqWriter

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/HDFSTestSeqWriter.java:28

ClassHDFSTestWriterFactory

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/HDFSTestWriterFactory.java:25

ClassHDFSTextSerializer

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSTextSerializer.java:28

ClassHDFSWritableSerializer

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSWritableSerializer.java:27

InterfaceHDFSWriter

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

ClassHDFSWriterFactory

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSWriterFactory.java:23

InterfaceHbaseEventSerializer

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

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

ClassHiveDelimitedTextSerializer

Forwards the incoming event body to Hive unmodified Sets up the delimiter and the field to column mapping

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java:35

InterfaceHiveEventSerializer

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

ClassHiveJsonSerializer

Forwards the incoming event body to Hive unmodified Sets up the delimiter and the field to column mapping

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveJsonSerializer.java:36

ClassHiveSink

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java:53

ClassHiveWriter

Internal API intended for HiveSink use.

code/flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java:45

ClassIRCConnectionListener

code/flume-ng-sinks/flume-irc-sink/src/main/java/org/apache/flume/sink/irc/IRCSink.java:63

ClassIRCSink

code/flume-ng-sinks/flume-irc-sink/src/main/java/org/apache/flume/sink/irc/IRCSink.java:40

ClassIncrementAsyncHBaseSerializer

An AsyncHBaseEventSerializer implementation that increments a configured column for the row whose row key is the event's body bytes.

code/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/IncrementAsyncHBaseSerializer.java:35

ClassIncrementHBaseSerializer

For Increment-related unit tests.

code/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/IncrementHBaseSerializer.java:36

InterfaceIndexNameBuilder

code/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/IndexNameBuilder.java:25

ClassKafkaConsumer

A Kafka Consumer implementation. This uses the current thread to fetch the next message from the queue and doesn't use a multi threaded implementation

code/flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/util/KafkaConsumer.java:42

ClassKafkaLocal

A local Kafka server for running unit tests. Reference: https://gist.github.com/fjavieralba/7930018/

code/flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/util/KafkaLocal.java:31

ClassKafkaSink

A Flume Sink that can publish messages to Kafka. This is a general implementation that can be used with any Flume agent and a channel. The message can

code/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java:105

ClassKafkaSinkConstants

code/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSinkConstants.java:23

ClassKerberosUser

Simple Pair class used to define a unique (principal, keyTab) combination.

code/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/KerberosUser.java:22

EnumKeyType

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleHbaseEventSerializer.java:139

ClassKfkAsyncHbaseEventSerializer

A simple serializer to be used with the AsyncHBaseSink that returns puts from an event, by writing the event body into it. The headers are discarded.

code/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/KfkAsyncHbaseEventSerializer.java:52

ClassLocalMorphlineInterceptor

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

ClassMockDataStream

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/MockDataStream.java:27

ClassMockFileSystem

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/MockFileSystem.java:34

ClassMockFsDataOutputStream

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/MockFsDataOutputStream.java:26

ClassMockHDFSWriter

code/flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/MockHDFSWriter.java:27

next →1–100 of 173, ranked by callers