public class EncoderOmit extends LegacyEncoder
| Constructor and Description |
|---|
EncoderOmit() |
EncoderOmit(boolean federated) |
EncoderOmit(int[] colList,
int clen) |
EncoderOmit(org.apache.wink.json4j.JSONObject parsedSpec,
String[] colnames,
int clen,
int minCol,
int maxCol) |
| Modifier and Type | Method and Description |
|---|---|
MatrixBlock |
apply(FrameBlock in,
MatrixBlock out)
Encode input data blockwise according to existing transform meta data (transform apply).
|
void |
build(FrameBlock in)
Build the transform meta data for the given block input.
|
MatrixBlock |
encode(FrameBlock in,
MatrixBlock out)
Block encode: build and apply (transform encode).
|
boolean |
equals(Object o) |
FrameBlock |
getMetaData(FrameBlock out)
Construct a frame block out of the transform meta data.
|
int |
getNumRemovedRows() |
int |
getNumRemovedRows(boolean[] rmRows) |
int |
hashCode() |
int |
initColList(int[] colList) |
void |
initMetaData(FrameBlock meta)
Sets up the required meta data for a subsequent call to apply.
|
boolean |
isApplicable()
Indicates if this encoder is applicable, i.e, if there is at least one column to encode.
|
void |
mergeAt(EncoderOmit other,
int row,
int col) |
boolean |
omit(String[] words,
TfUtils agents) |
void |
readExternal(ObjectInput in)
Redirects the default java serialization via externalizable to our default hadoop writable serialization for
efficient broadcast/rdd deserialization.
|
EncoderOmit |
subRangeEncoder(IndexRange ixRange)
Returns a new Encoder that only handles a sub range of columns.
|
void |
updateIndexRanges(long[] beginDims,
long[] endDims)
Update index-ranges to after encoding.
|
void |
writeExternal(ObjectOutput out)
Redirects the default java serialization via externalizable to our default hadoop writable serialization for
efficient broadcast/rdd serialization.
|
buildPartial, getColList, getColMapping, initColList, isApplicable, mergeAt, prepareBuildPartial, setColList, shiftColspublic EncoderOmit(org.apache.wink.json4j.JSONObject parsedSpec,
String[] colnames,
int clen,
int minCol,
int maxCol)
throws org.apache.wink.json4j.JSONException
org.apache.wink.json4j.JSONExceptionpublic EncoderOmit()
public EncoderOmit(int[] colList,
int clen)
public EncoderOmit(boolean federated)
public int initColList(int[] colList)
initColList in class LegacyEncoderpublic boolean isApplicable()
isApplicable in class LegacyEncoderpublic int getNumRemovedRows(boolean[] rmRows)
public int getNumRemovedRows()
public MatrixBlock encode(FrameBlock in, MatrixBlock out)
LegacyEncoderencode in class LegacyEncoderin - input frame blockout - output matrix blockpublic void build(FrameBlock in)
LegacyEncoderbuild in class LegacyEncoderin - input frame blockpublic MatrixBlock apply(FrameBlock in, MatrixBlock out)
LegacyEncoderapply in class LegacyEncoderin - input frame blockout - output matrix blockpublic EncoderOmit subRangeEncoder(IndexRange ixRange)
LegacyEncodersubRangeEncoder in class LegacyEncoderixRange - the range (1-based, begin inclusive, end exclusive)public void mergeAt(EncoderOmit other, int row, int col)
public void updateIndexRanges(long[] beginDims,
long[] endDims)
LegacyEncoderupdateIndexRanges in class LegacyEncoderbeginDims - begin dimensions of rangeendDims - end dimensions of rangepublic FrameBlock getMetaData(FrameBlock out)
LegacyEncodergetMetaData in class LegacyEncoderout - output frame blockpublic void initMetaData(FrameBlock meta)
LegacyEncoderinitMetaData in class LegacyEncodermeta - frame blockpublic void writeExternal(ObjectOutput out) throws IOException
LegacyEncoderwriteExternal in interface ExternalizablewriteExternal in class LegacyEncoderout - object outputIOException - if IOException occurspublic void readExternal(ObjectInput in) throws IOException
LegacyEncoderreadExternal in interface ExternalizablereadExternal in class LegacyEncoderin - object inputIOException - if IOException occurCopyright © 2021 The Apache Software Foundation. All rights reserved.