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

Attributes.getSeq_id介绍

暂无

代码示例

代码示例来源：origin: amidst/toolbox

private static long getSequenceID(DataInstance tailInstance){
  return (long)tailInstance.getValue(tailInstance.getAttributes().getSeq_id());
}

代码示例来源：origin: amidst/toolbox

int id = (int)d.getValue(dataInstances.getAttributes().getSeq_id());
  return map.get(id).compareTo(year)==0;
}).collect(Collectors.toList());

代码示例来源：origin: amidst/toolbox

public DynamicDataInstanceWrapper(DataInstance dataInstance) {
  this.dataInstance = dataInstance;
  seqID = this.dataInstance.getAttributes().getSeq_id();
  timeID = this.dataInstance.getAttributes().getTime_id();
}

代码示例来源：origin: amidst/toolbox

public static DataFlink<DynamicDataInstance> convertToDynamic(DataFlink<DataInstance> data){
  if (data.getAttributes().getSeq_id()==null && data.getAttributes().getTime_id()==null){
    throw new IllegalArgumentException("Data with no seq_id and time_id attribute can not be converged");
  }
  return new DataWrapper(data);
}

代码示例来源：origin: amidst/toolbox

private void replicateModelForDocs() {
  replicatedNodes = new ArrayList<>();
  Attribute seqIDAtt = this.attributes.getSeq_id();
  double currentID = 0;
  List<Node> tmpNodes = new ArrayList<>();

代码示例来源：origin: amidst/toolbox

private void replicateModelForDocs() {
  replicatedNodes = new ArrayList<>();
  Attribute seqIDAtt = this.attributes.getSeq_id();
  double currentID = 0;
  List<Node> tmpNodes = new ArrayList<>();

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosterior> computePosterior(){
  Attribute seq_id = this.dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    return this.dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInference())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosterior> computePosterior(DataFlink<DataInstance> dataFlink){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    return dataFlink
        .getBatchedDataSet(this.batchSize,batchConverter)
        .flatMap(new ParallelVBMapInference())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosterior> computePosterior(DataFlink<DataInstance> dataFlink){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    return dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInference())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}
public double updateModel(DataFlink<DataInstance> dataUpdate){

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosterior> computePosterior(DataFlink<DataInstance> dataFlink){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    return dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInference())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}
public double updateModel(DataFlink<DataInstance> dataUpdate){

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosteriorAssignment> computePosteriorAssignment(List<Variable> latentVariables){
  Attribute seq_id = this.dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    config.setBytes(LATENT_VARS, Serialization.serializeObject(latentVariables));
    return this.dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInferenceAssignment())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosteriorAssignment> computePosteriorAssignment(DataFlink<DataInstance> dataFlink, List<Variable> latentVariables){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    config.setBytes(LATENT_VARS, Serialization.serializeObject(latentVariables));
    return dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInferenceAssignment())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosterior> computePosterior(DataFlink<DataInstance> dataFlink, List<Variable> latentVariables){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    config.setBytes(LATENT_VARS, Serialization.serializeObject(latentVariables));
    return dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInference())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosteriorAssignment> computePosteriorAssignment(DataFlink<DataInstance> dataFlink, List<Variable> latentVariables){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    config.setBytes(LATENT_VARS, Serialization.serializeObject(latentVariables));
    return dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInferenceAssignment())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosterior> computePosterior(List<Variable> latentVariables){
  Attribute seq_id = this.dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    config.setBytes(LATENT_VARS, Serialization.serializeObject(latentVariables));
    return this.dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInference())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosterior> computePosterior(DataFlink<DataInstance> dataFlink, List<Variable> latentVariables){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    config.setBytes(LATENT_VARS, Serialization.serializeObject(latentVariables));
    return dataFlink
        .getBatchedDataSet(this.batchSize,batchConverter)
        .flatMap(new ParallelVBMapInference())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosterior> computePosterior(DataFlink<DataInstance> dataFlink, List<Variable> latentVariables){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.dag.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    config.setBytes(LATENT_VARS, Serialization.serializeObject(latentVariables));
    return dataFlink
        .getBatchedDataSet(this.batchSize)
        .flatMap(new ParallelVBMapInference())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

public DataSet<DataPosteriorAssignment> computePosteriorAssignment(DataFlink<DataInstance> dataFlink, List<Variable> latentVariables){
  Attribute seq_id = dataFlink.getAttributes().getSeq_id();
  if (seq_id==null)
    throw new IllegalArgumentException("Functionality only available for data sets with a seq_id attribute");
  try{
    Configuration config = new Configuration();
    config.setString(ParameterLearningAlgorithm.BN_NAME, this.getName());
    config.setBytes(SVB, Serialization.serializeObject(svb));
    config.setBytes(LATENT_VARS, Serialization.serializeObject(latentVariables));
    return dataFlink
        .getBatchedDataSet(this.batchSize,batchConverter)
        .flatMap(new ParallelVBMapInferenceAssignment())
        .withParameters(config);
  }catch(Exception ex){
    throw new UndeclaredThrowableException(ex);
  }
}

代码示例来源：origin: amidst/toolbox

attSequenceID = this.reader.getAttributes().getSeq_id();
if (attSequenceID!=null)
  sequenceID = (int)present.getValue(attSequenceID);

代码示例来源：origin: amidst/toolbox

Attribute seqID = this.attributes.getSeq_id();
int currentDocID = -1;
int nDocs = 0;