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, shiftCols
public 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.JSONException
public EncoderOmit()
public EncoderOmit(int[] colList, int clen)
public EncoderOmit(boolean federated)
public int initColList(int[] colList)
initColList
in class LegacyEncoder
public boolean isApplicable()
isApplicable
in class LegacyEncoder
public int getNumRemovedRows(boolean[] rmRows)
public int getNumRemovedRows()
public MatrixBlock encode(FrameBlock in, MatrixBlock out)
LegacyEncoder
encode
in class LegacyEncoder
in
- input frame blockout
- output matrix blockpublic void build(FrameBlock in)
LegacyEncoder
build
in class LegacyEncoder
in
- input frame blockpublic MatrixBlock apply(FrameBlock in, MatrixBlock out)
LegacyEncoder
apply
in class LegacyEncoder
in
- input frame blockout
- output matrix blockpublic EncoderOmit subRangeEncoder(IndexRange ixRange)
LegacyEncoder
subRangeEncoder
in class LegacyEncoder
ixRange
- the range (1-based, begin inclusive, end exclusive)public void mergeAt(EncoderOmit other, int row, int col)
public void updateIndexRanges(long[] beginDims, long[] endDims)
LegacyEncoder
updateIndexRanges
in class LegacyEncoder
beginDims
- begin dimensions of rangeendDims
- end dimensions of rangepublic FrameBlock getMetaData(FrameBlock out)
LegacyEncoder
getMetaData
in class LegacyEncoder
out
- output frame blockpublic void initMetaData(FrameBlock meta)
LegacyEncoder
initMetaData
in class LegacyEncoder
meta
- frame blockpublic void writeExternal(ObjectOutput out) throws IOException
LegacyEncoder
writeExternal
in interface Externalizable
writeExternal
in class LegacyEncoder
out
- object outputIOException
- if IOException occurspublic void readExternal(ObjectInput in) throws IOException
LegacyEncoder
readExternal
in interface Externalizable
readExternal
in class LegacyEncoder
in
- object inputIOException
- if IOException occurCopyright © 2021 The Apache Software Foundation. All rights reserved.