本文整理了Java中com.addthis.bundle.core.Bundle.getFormat()
方法的一些代码示例,展示了Bundle.getFormat()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bundle.getFormat()
方法的具体详情如下:
包路径:com.addthis.bundle.core.Bundle
类名称:Bundle
方法名:getFormat
暂无
代码示例来源:origin: addthis/hydra
@Override
public void appendBundleToString(Bundle row, StringBuilder stringBuilder) {
stringBuilder.append("<tr>");
for (BundleField field : row.getFormat()) {
ValueObject o = row.getValue(field);
stringBuilder.append("<td>").append(o).append("</td>");
}
stringBuilder.append("</tr>\n");
}
代码示例来源:origin: addthis/hydra
public static String buildRow(Bundle row, String delimiter) {
StringBuilder stringBuilder = new StringBuilder(row.getFormat().getFieldCount() * 12 + 1);
buildRow(row, delimiter, stringBuilder);
return stringBuilder.toString();
}
代码示例来源:origin: addthis/hydra
public static String buildRow(Bundle row, String delimiter) {
StringBuilder stringBuilder = new StringBuilder(row.getFormat().getFieldCount() * 12 + 1);
buildRow(row, delimiter, stringBuilder);
return stringBuilder.toString();
}
代码示例来源:origin: addthis/hydra
private static Bundle cloneBundle(Bundle input) {
Bundle output = input.createBundle();
Iterator<BundleField> fieldIterator = input.getFormat().iterator();
while (fieldIterator.hasNext()) {
BundleField field = fieldIterator.next();
output.setValue(field, input.getValue(field));
}
return output;
}
代码示例来源:origin: addthis/hydra
protected void mergeBundles(Bundle orig, Bundle nBundle) {
for (BundleField bf : nBundle) {
orig.setValue(orig.getFormat().getField(bf.getName()), nBundle.getValue(bf));
}
}
代码示例来源:origin: addthis/hydra
@Override
public boolean updateChildData(DataTreeNodeUpdater state, DataTreeNode childNode, Config conf) {
Bundle bundle = state.getBundle();
if (keyAccess == null) {
keyAccess = bundle.getFormat().getField(conf.key);
}
return updateCounter(bundle, bundle.getValue(keyAccess));
}
代码示例来源:origin: addthis/hydra
@Override
public boolean updateChildData(DataTreeNodeUpdater state, DataTreeNode tn, Config conf) {
Bundle p = state.getBundle();
if (keyAccess == null) {
keyAccess = p.getFormat().getField(conf.key);
}
updateCounter(p.getValue(keyAccess));
return true;
}
代码示例来源:origin: addthis/hydra
protected Bundle makeAltBundle(Bundle bundle) {
ListBundleFormat format = new ListBundleFormat();
Bundle alt = new ListBundle(format);
for (int i = 0; i < columns.length; i++) {
BundleField field = format.getField(columns[i]);
alt.setValue(field, bundle.getValue(bundle.getFormat().getField(columns[i])));
}
return alt;
}
代码示例来源:origin: addthis/hydra
@Override
public boolean updateChildData(DataTreeNodeUpdater state, DataTreeNode childNode, Config conf) {
Bundle p = state.getBundle();
if (keyAccess == null) {
keyAccess = p.getFormat().getField(conf.key);
}
ValueObject o = p.getValue(keyAccess);
if (o != null) {
bloom.setSeen(Raw.get(ValueUtil.asNativeString(o)));
}
return true;
}
代码示例来源:origin: addthis/hydra
@Test
public void noErrorsShouldBeThrown() {
// there is no map
builder.process(bundle, emitter);
// map not a map
bundle.setValue(bundle.getFormat().getField("foo"), ValueFactory.create("notamap"));
builder.process(bundle, emitter);
verify(emitter, never()).emit(any());
}
代码示例来源:origin: addthis/hydra
@Test
public void emitOriginalNoMapField() throws IOException {
bundle.setValue(bundle.getFormat().getField("bar"), ValueFactory.create("biz"));
builder = Configs.decodeObject(StreamMapSplitBuilder.class, "field: foo, keyField: key, valueField: value, emitOriginal: false");
builder.process(bundle, emitter);
verify(emitter, never()).emit(any());;
}
代码示例来源:origin: addthis/hydra
@Test
public void testMult() {
BundleFilterNum bfn = new BundleFilterNum("c0,n3,*,v1,set", null);
Bundle bundle = new ListBundle();
bundle.setValue(bundle.getFormat().getField("c0"), ValueFactory.create(3));
bundle.setValue(bundle.getFormat().getField("c1"), ValueFactory.create(4));
bfn.filter(bundle);
assertEquals("9", bundle.getValue(bundle.getFormat().getField("c1")).toString());
}
代码示例来源:origin: addthis/hydra
@Test
public void testAdd() {
BundleFilterNum bfn = new BundleFilterNum("c0,n3,add,v1,set", null);
Bundle bundle = new ListBundle();
bundle.setValue(bundle.getFormat().getField("c0"), ValueFactory.create(3));
bundle.setValue(bundle.getFormat().getField("c1"), ValueFactory.create(4));
bfn.filter(bundle);
assertEquals(bundle.getValue(bundle.getFormat().getField("c1")).toString(), "6");
}
代码示例来源:origin: addthis/hydra
@Test
public void testMean() {
BundleFilterNum bfn = new BundleFilterNum("n2:3:5:7:11:13:17:19,mean,v0,set", null);
Bundle bundle = new ListBundle();
bundle.setValue(bundle.getFormat().getField("c1"), ValueFactory.create(-1));
bfn.filter(bundle);
assertEquals("9.625", bundle.getValue(bundle.getFormat().getField("c1")).toString());
}
代码示例来源:origin: addthis/hydra
@Test
public void testVariance() {
BundleFilterNum bfn = new BundleFilterNum("n2:3:5:7:11:13:17:19,variance,v0,set", null);
Bundle bundle = new ListBundle();
bundle.setValue(bundle.getFormat().getField("c1"), ValueFactory.create(-1));
bfn.filter(bundle);
assertEquals("35.734375", bundle.getValue(bundle.getFormat().getField("c1")).toString());
}
代码示例来源:origin: addthis/hydra
@Test
public void testPop() {
BundleFilterNum bfn = new BundleFilterNum("n1:2:3,pop,v0,set", null);
Bundle bundle = new ListBundle();
bundle.setValue(bundle.getFormat().getField("c1"), ValueFactory.create(-1));
bfn.filter(bundle);
assertEquals("2", bundle.getValue(bundle.getFormat().getField("c1")).toString());
}
代码示例来源:origin: addthis/hydra
@Test
public void testInsertArrayString() {
BundleFilterNum bfn = new BundleFilterNum("c0,mean,v1,set", null);
Bundle bundle = new ListBundle();
bundle.setValue(bundle.getFormat().getField("c0"), ValueFactory.create("1,2,3,4,5"));
bundle.setValue(bundle.getFormat().getField("c1"), ValueFactory.create(0.0));
bfn.filter(bundle);
assertEquals(ValueFactory.create(3.0), bundle.getValue(bundle.getFormat().getField("c1")));
}
代码示例来源:origin: addthis/hydra
private static void compareBundles(Bundle expect, Bundle got) {
for (BundleField field : expect.getFormat()) {
ValueObject v1 = expect.getValue(field);
ValueObject v2 = got.getValue(field);
assertEquals(v1, v2);
}
assertEquals("column count mismatch", expect.getCount(), got.getCount());
}
代码示例来源:origin: addthis/hydra
@Test
public void basicJoin() throws Exception {
BundleFilter concat = Configs.decodeObject(BundleFilterConcat.class, "in = [a, b], out = b, join = \", \"");
Bundle bundle = new ListBundle();
BundleFilter setup = Configs.decodeObject(
BundleFilter.class, "chain: [{from.const: hi, to: a}, {from.const: there, to: b}]");
setup.filter(bundle);
concat.filter(bundle);
assertEquals("hi, there", bundle.getValue(bundle.getFormat().getField("b")).toString());
}
}
代码示例来源:origin: addthis/hydra
@Test
public void testNumberFormatException() {
BundleFilterNum bfn = new BundleFilterNum("c0,v1,set", null);
Bundle bundle = new ListBundle();
bundle.setValue(bundle.getFormat().getField("c0"), ValueFactory.create("hello"));
boolean success = bfn.filter(bundle);
assertFalse(success);
}
内容来源于网络,如有侵权,请联系作者删除!