public class TransformProcess
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Class and Description |
---|---|
static class |
TransformProcess.Builder
Builder class for constructing a TransformProcess
|
Constructor and Description |
---|
TransformProcess(Schema initialSchema,
java.util.List<DataAction> actionList) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Writable> |
execute(java.util.List<Writable> input)
Execute the full sequence of transformations for a single example.
|
java.util.List<java.util.List<Writable>> |
executeSequence(java.util.List<java.util.List<Writable>> inputSequence)
Execute the full sequence of transformations for a single time series (sequence).
|
java.util.List<java.util.List<Writable>> |
executeSequenceToSequence(java.util.List<java.util.List<Writable>> input) |
static TransformProcess |
fromJson(java.lang.String json)
Deserialize a JSON String (created by
toJson() ) to a TransformProcess |
static TransformProcess |
fromYaml(java.lang.String yaml)
Deserialize a JSON String (created by
toJson() ) to a TransformProcess |
java.util.List<DataAction> |
getActionList() |
Schema |
getFinalSchema()
Get the Schema of the output data, after executing the process
|
Schema |
getSchemaAfterStep(int step)
Return the schema after executing all steps up to and including the specified step.
|
java.lang.String |
toJson()
Convert the TransformProcess to a JSON string
|
java.lang.String |
toYaml()
Convert the TransformProcess to a YAML string
|
java.util.List<Writable> |
transformRawStringsToInput(java.lang.String... values)
Based on the input schema,
map raw string values to the appropriate
writable
|
public TransformProcess(Schema initialSchema, java.util.List<DataAction> actionList)
public java.util.List<DataAction> getActionList()
public Schema getFinalSchema()
public Schema getSchemaAfterStep(int step)
step
- Index of the steppublic java.util.List<Writable> execute(java.util.List<Writable> input)
input
- public java.util.List<java.util.List<Writable>> executeSequenceToSequence(java.util.List<java.util.List<Writable>> input)
input
- public java.util.List<java.util.List<Writable>> executeSequence(java.util.List<java.util.List<Writable>> inputSequence)
public java.lang.String toJson()
public java.lang.String toYaml()
public static TransformProcess fromJson(java.lang.String json)
toJson()
) to a TransformProcesspublic static TransformProcess fromYaml(java.lang.String yaml)
toJson()
) to a TransformProcesspublic java.util.List<Writable> transformRawStringsToInput(java.lang.String... values)
values
- the values to convert