B C G O P S T V W
All Classes All Packages

B

build() - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Convenience method to build the underlying topology

C

COMMIT - org.locationtech.geomesa.kafka.utils.interop.GeoMessageProcessor.BatchResult

consume(List<GeoMessage>) - Method in interface org.locationtech.geomesa.kafka.utils.interop.GeoMessageProcessor

Consume a batch of records.

consume(Seq<GeoMessage>) - Method in interface org.locationtech.geomesa.kafka.utils.interop.GeoMessageProcessor

consume(Seq<GeoMessage>) - Method in interface org.locationtech.geomesa.kafka.utils.interop.GeoMessageProcessor

CONTINUE - org.locationtech.geomesa.kafka.utils.interop.GeoMessageProcessor.BatchResult

create(Map<String, String>) - Static method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a streams builder

create(Map<String, String>, TimestampExtractor) - Static method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a streams builder

create(Map<String, String>, TimestampExtractor, StreamsBuilder) - Static method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a streams builder

create(Map<String, String>, TimestampExtractor, Topology.AutoOffsetReset) - Static method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a streams builder

create(Map<String, String>, TimestampExtractor, Topology.AutoOffsetReset, StreamsBuilder) - Static method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a streams builder

create(Map<String, String>, StreamsBuilder) - Static method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a streams builder

create(Map<String, String>, Topology.AutoOffsetReset) - Static method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a streams builder

create(Map<String, String>, Topology.AutoOffsetReset, StreamsBuilder) - Static method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a streams builder

G

GeoMesaStreamsBuilder - Class in org.locationtech.geomesa.kafka.jstreams

Wrapper for a kafka streams builder that will configure serialization based on a GeoMesa Kafka feature store

GeoMessageProcessor - Interface in org.locationtech.geomesa.kafka.utils.interop

Message processor class.

GeoMessageProcessor.BatchResult - Enum in org.locationtech.geomesa.kafka.utils.interop

globalTable(String) - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a global table for a given feature type

globalTable(String, Materialized<String, GeoMesaMessage, KeyValueStore<Bytes, byte[]>>) - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a global table for a given feature type

O

org.locationtech.geomesa.kafka.jstreams - package org.locationtech.geomesa.kafka.jstreams

org.locationtech.geomesa.kafka.utils.interop - package org.locationtech.geomesa.kafka.utils.interop

P

PAUSE - org.locationtech.geomesa.kafka.utils.interop.GeoMessageProcessor.BatchResult

S

serde(String) - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Get the `GeoMesaMessage` serde for the given feature type

stream(String) - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a stream of updates for a given feature type

T

table(String) - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a table for a given feature type

table(String, Materialized<String, GeoMesaMessage, KeyValueStore<Bytes, byte[]>>) - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Create a table for a given feature type

to(String, KStream<String, GeoMesaMessage>) - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Write the stream to the given feature type, which must already exist.

V

valueOf(String) - Static method in enum org.locationtech.geomesa.kafka.utils.interop.GeoMessageProcessor.BatchResult

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.locationtech.geomesa.kafka.utils.interop.GeoMessageProcessor.BatchResult

Returns an array containing the constants of this enum type, in the order they are declared.

W

wrapped() - Method in class org.locationtech.geomesa.kafka.jstreams.GeoMesaStreamsBuilder

Get the underlying streams builder

B C G O P S T V W
All Classes All Packages