Class and Description |
---|
LocalStrategy
Enumeration of all available local processing strategies tasks.
|
Class and Description |
---|
LocalStrategy
Enumeration of all available local processing strategies tasks.
|
Class and Description |
---|
DistributedRuntimeUDFContext
A standalone implementation of the
RuntimeContext , created by runtime UDF operators. |
Class and Description |
---|
TaskConfig
Configuration class which stores all relevant parameters required to set up the Pact tasks.
|
Class and Description |
---|
CloseableInputProvider
Utility interface for a provider of an input that can be closed.
|
DistributedRuntimeUDFContext
A standalone implementation of the
RuntimeContext , created by runtime UDF operators. |
JoinTaskIterator
Interface of an iterator that performs the logic of a match task.
|
TaskConfig
Configuration class which stores all relevant parameters required to set up the Pact tasks.
|
Class and Description |
---|
TaskConfig
Configuration class which stores all relevant parameters required to set up the Pact tasks.
|
Class and Description |
---|
JoinTaskIterator
Interface of an iterator that performs the logic of a match task.
|
Class and Description |
---|
CloseableInputProvider
Utility interface for a provider of an input that can be closed.
|
CoGroupTaskIterator
Interface describing the methods that have to be implemented by local strategies for the CoGroup Pact.
|
JoinTaskIterator
Interface of an iterator that performs the logic of a match task.
|
Class and Description |
---|
BitSet |
CloseableInputProvider
Utility interface for a provider of an input that can be closed.
|
LocalStrategy
Enumeration of all available local processing strategies tasks.
|
TaskConfig
Configuration class which stores all relevant parameters required to set up the Pact tasks.
|
Class and Description |
---|
CloseableInputProvider
Utility interface for a provider of an input that can be closed.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.