com.addthis.bundle.core.Bundle.getFormat()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(7.0k)|赞(0)|评价(0)|浏览(171)

本文整理了Java中com.addthis.bundle.core.Bundle.getFormat()方法的一些代码示例,展示了Bundle.getFormat()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bundle.getFormat()方法的具体详情如下:
包路径:com.addthis.bundle.core.Bundle
类名称:Bundle
方法名:getFormat

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);
}

相关文章