Examples of Tuple


Examples of backtype.storm.tuple.Tuple

  public static Tuple mockTickTuple() {
    return mockTuple(Constants.SYSTEM_COMPONENT_ID, Constants.SYSTEM_TICK_STREAM_ID);
  }

  public static Tuple mockTuple(String componentId, String streamId) {
    Tuple tuple = mock(Tuple.class);
    when(tuple.getSourceComponent()).thenReturn(componentId);
    when(tuple.getSourceStreamId()).thenReturn(streamId);
    return tuple;
  }
View Full Code Here

Examples of biz.smart.mdx.olap.data.Tuple

   
    for(Hierarchy hierarchy : analyzedHierarchies){
      tupleMembers.put(hierarchy, hierarchy.getHierarchyAllAsMember());
    }
   
    Tuple tuple = new Tuple(tupleMembers);
   
    MdxValueExpression secWithExpr =
      new MdxValueExpression("'( "+mdxQuery.getMeasure()+"/"+tuple.toString()+")',FORMAT_STRING = \"Percent\"",
          mdxQuery.getMeasure().getMemberExpression(label).getDefinition(),
          tuple.getHierarchies());
   
    return secWithExpr;
  }
View Full Code Here

Examples of ca.eandb.jmist.math.Tuple

  private static LinearMatrix3 generateXYZ2Band() {
    double a[][] = new double[3][3];

    for (int i = 0; i < 3; i++) {
      final int _i = i;
      Tuple basis = ColorUtil.XYZ_WAVELENGTHS.map(new Tuple.Function() {
        public double apply(double value) {
          return MathUtil.inRangeCO(value, (400 + (100 * _i)) * 1e-9, (500 + (100 * _i)) * 1e-9) ? 1.0 : 0.0;
        }
      });

View Full Code Here

Examples of cartago.Tuple

  public TupleFilter(Tuple t){
    tuple = t;
  }
 
  public boolean select(ArtifactObsEvent ev){
    Tuple sig = ev.getSignal();
    if (sig != null){
      if (tuple.getLabel().equals(sig.getLabel()) && tuple.getNArgs() == sig.getNArgs()){
        for (int i = 0; i < tuple.getNArgs(); i++){
          Object arg = tuple.getContent(i);
          if (arg!=null && !arg.equals(sig.getContent(i))){
            return false;
          }
        }
        return true;
      } else {
View Full Code Here

Examples of cascading.tuple.Tuple

            return false;
        }

        @Override
        public void sink(FlowProcess<JobConf> flowProcess, SinkCall<Object, Object> sinkCall) throws IOException {
            Tuple tuple = sinkCall.getOutgoingEntry().getTuple();
            StringBuffer sb = new StringBuffer();
            for (Object object : tuple) {
                if (object instanceof Writable) {
                    sb.append(WritableUtils.fromWritable((Writable) object));
                }
View Full Code Here

Examples of cascading.tuple.Tuple

        }

        static Tuple coerceToString(SinkCall<?, ?> sinkCall) {
            TupleEntry entry = sinkCall.getOutgoingEntry();
            Fields fields = entry.getFields();
            Tuple tuple = entry.getTuple();

            if (fields.hasTypes()) {
                Type types[] = new Type[fields.size()];
                for (int index = 0; index < fields.size(); index++) {
                    Type type = fields.getType(index);
View Full Code Here

Examples of cascading.tuple.Tuple

        Assert.isTrue(from instanceof SinkCall,
                String.format("Unexpected object type, expecting [%s], given [%s]", SinkCall.class, from.getClass()));

        // handle common cases
        SinkCall sinkCall = (SinkCall) from;
        Tuple rawTuple = sinkCall.getOutgoingEntry().getTuple();

        if (rawTuple == null || rawTuple.isEmpty()) {
            to.bytes("{}");
            return;
        }
        Assert.isTrue(rawTuple.size() == 1, "When using JSON input, only one field is expected");

        // postpone the coercion
        Tuple tuple = CascadingUtils.coerceToString(sinkCall);
        super.convert(tuple.getObject(0), to);
    }
View Full Code Here

Examples of cascading.tuple.Tuple

    }

    @SuppressWarnings("unchecked")
    @Override
    public boolean write(SinkCall<Object[], ?> sinkCall, Generator generator) {
        Tuple tuple = CascadingUtils.coerceToString(sinkCall);
        // consider names (in case of aliases these are already applied)
        List<String> names = (List<String>) sinkCall.getContext()[0];

        generator.writeBeginObject();
        for (int i = 0; i < tuple.size(); i++) {
            String name = (i < names.size() ? names.get(i) : "tuple" + i);
            generator.writeFieldName(name);
            Object object = tuple.getObject(i);
            if (!jdkWriter.write(object, generator)) {
                if (!(object instanceof Writable) || !writableWriter.write((Writable) object, generator)) {
                    return false;
                }
            }
View Full Code Here

Examples of ceylon.language.Tuple

    }

    @Override
    public Iterator<? extends Sequence<? extends Object>> iterator() {
        ValueDeclaration valueDecl = null;
        return new Singleton(null, new Tuple(null, new Object[]{
                valueDecl,
                value
        })).iterator();
    }
View Full Code Here

Examples of ch.ethz.prose.query.Tuple

  public synchronized void allAspects() throws RemoteException,IllegalUserInputException {
    checkIsConnected();
    table = new Vector();
    Iterator i = exMngr.allAspects().iterator();
    while (i.hasNext()) {
      table.add(new Tuple((AspectSurrogate)i.next(), null, null));
    }
    convertDataForGUI();
    updateTable(data);
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.