Package com.liveramp.cascading_ext

Examples of com.liveramp.cascading_ext.TupleSerializationUtil

38
39
40
41
42
43
44
  }

  @Override
  public void prepare(FlowProcess flowProcess, OperationCall operationCall) {
    super.prepare(flowProcess, operationCall);
    tupleSerializationUtil = new TupleSerializationUtil((JobConf) flowProcess.getConfigCopy());
  }
View Full Code Here
114
115
116
117
118
119
120
    @Override
    public void prepare(FlowProcess flowProcess, OperationCall operationCall) {
      JobConf conf = (JobConf) flowProcess.getConfigCopy();
      approxCounter = new HyperLogLog(BloomProps.getHllErr(conf));
      sampleRate = BloomProps.getKeySampleRate(conf);
      tupleSerializationUtil = new TupleSerializationUtil((JobConf) flowProcess.getConfigCopy());
    }
View Full Code Here
66
67
68
69
70
71
72
        definition.getValueSizeEstimator());
    key = new TupleEntry(definition.getGroupFields(), Tuple.size(definition.getGroupFields().size()));
    input = new TupleEntry(definition.getInputFields(), Tuple.size(definition.getInputFields().size()));
    keyFieldsPos = Lists.newArrayList();
    inputFieldsPos = Lists.newArrayList();
    this.serializationUtil = new TupleSerializationUtil(conf);
  }
View Full Code Here
224
225
226
227
228
229
230
      super(new Fields("serialized-tuple-key"));
    }

    @Override
    public void prepare(FlowProcess flowProcess, OperationCall operationCall) {
      tupleSerializationUtil = new TupleSerializationUtil((JobConf) flowProcess.getConfigCopy());
    }
View Full Code Here
TOP

Related Classes of com.liveramp.cascading_ext.TupleSerializationUtil

  • cascading.tuple.hadoop.io.HadoopTupleInputStream
  • cascading.tuple.hadoop.io.HadoopTupleOutputStream
  • cascading.tuple.hadoop.TupleSerialization
  • cascading.tuple.io.TupleInputStream
  • cascading.tuple.Tuple
  • com.liveramp.cascading_ext.assembly.BloomAssembly$GetSerializedTuple
  • com.liveramp.cascading_ext.assembly.CreateBloomFilter$CollectKeyStats
  • com.liveramp.cascading_ext.bloom.operation.BloomJoinFilter
  • com.liveramp.cascading_ext.combiner.CombinerFunctionContext
  • java.io.ByteArrayOutputStream
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.