Package | Description |
---|---|
com.hazelcast.jet.pipeline.file |
This package offers the
FileSourceBuilder
which allows you to construct various kinds of Pipeline sources that read from local or distributed files. |
Modifier and Type | Method and Description |
---|---|
static <T> AvroFileFormat<T> |
FileFormat.avro()
Returns a file format for Avro files.
|
static <T> AvroFileFormat<T> |
FileFormat.avro(Class<T> clazz)
Returns a file format for Avro files that specifies to use reflection
to deserialize the data into instances of the provided Java class.
|
AvroFileFormat<T> |
AvroFileFormat.withReflect(Class<T> reflectClass)
Specifies to use reflection to deserialize data into the given class.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.