138139140141142143144145
public Datum deserialize(DataInput in) throws SerDeException { try { // TODO: should we write the bytes ourselves? get around 32k limit? return new StringDatum(in.readUTF()); } catch (IOException e) { throw new SerDeException(e); } }
148149150151152153154155
public void serialize(Datum value, DataOutput out) throws SerDeException { try { out.writeUTF(value.asString()); } catch (IOException e) { throw new SerDeException(e); } }
526527528529530531532533
maxSize, digestFunction, baseSet, setFactory, sampleRate ); return sampledSet; } catch (IOException e) { throw new SerDeException(e); } }
548549550551552553554555
for (T element : elements) { elementSerDe.serialize(element, out); } } catch (IOException e) { throw new SerDeException(e); } }
3334353637383940
for (long item : value) { out.writeLong(item); } } catch (IOException e) { throw new SerDeException(e); } }
523524525526527528529530
545546547548549550551552
93949596979899100
DateTime dateKey = new DateTime(dateKeyMillis, DateTimeZone.UTC); K key = keySerDe.deserialize(in); return new TimeStamped<K>(dateKey, key); } catch (IOException e) { throw new SerDeException(e); } }
104105106107108109110111
throws SerDeException { try { out.writeLong(value.dateKey.getMillis()); keySerDe.serialize(value.key, out); } catch (IOException e) { throw new SerDeException(e); } }
146147148149150151152153