学習データモデルの更新を行なわず、LOF値の算出のみを行う。

@param recievedPoint 受信データ
@param dataSet 学習モデルデータ
@return LOF値算出結果
554585
protected double calculateLofWithoutUpdate(LofPoint recievedPoint, LofDataSet dataSet)
    {
        double result = 0.0d;

        if (this.hasIntermediate)
        {
            result = LofCalculator.calculateLofWithoutUpdate(this.kn, recievedPoint, dataSet);
        }
        else
        {
            result = LofCalculator.calculateLofNoIntermediate(this.kn, recievedPoint, dataSet);
        }

        return result;
    }
521789
public static List<List<Writable>> toRecords(DataSet dataSet) {
        if (isClassificationDataSet(dataSet)) {
            return getClassificationWritableMatrix(dataSet);
        } else {
            return getRegressionWritableMatrix(dataSet);
        }
    }
209122
function(dataset){
    this.sources.push(dataset);
    // add event listeners to source
    if (this.listen.source)
      dataset.addHandler(this.listen.source, this);

    // process new dataset objects and update member map
    var memberMap = this.members_;
    for (var objectId in dataset.items_)
    {
      // check: is this object already known
      if (memberMap[objectId])
      {
        // item exists -> increase dataset links count
        memberMap[objectId].count++;
      }
      else
      {
        // add to source map
        memberMap[objectId] = {
          count: 1,
          isMember: false,
          object: dataset.items_[objectId]
        };
      }
    }

    return true;
  }
980335
private MRCompactorJobRunner getMRCompactorJobRunner(Dataset dataset) {
    try {
      @SuppressWarnings("unchecked")
      Class<? extends MRCompactorJobRunner> cls = (Class<? extends MRCompactorJobRunner>) Class
          .forName(this.state.getProp(COMPACTION_JOB_RUNNER_CLASS, DEFAULT_COMPACTION_JOB_RUNNER_CLASS));
      return cls.getDeclaredConstructor(Dataset.class, FileSystem.class).newInstance(dataset, this.fs);
    } catch (Exception e) {
      throw new RuntimeException("Cannot instantiate MRCompactorJobRunner", e);
    }
  }
260860
public static void checkUpdate(DatasetDescriptor existing,
                                 DatasetDescriptor updated) {
    checkNotChanged("location", existing.getLocation(), updated.getLocation());
    checkCompatible(existing, updated);
  }
286783
public function get($projectId, $datasetId, $optParams = array()) {
      $params = array('projectId' => $projectId, 'datasetId' => $datasetId);
      $params = array_merge($params, $optParams);
      $data = $this->__call('get', array($params));
      if ($this->useObjects()) {
        return new Dataset($data);
      } else {
        return $data;
      }
    }
679107
public void addDataPointSet(String series, Set<DataPoint> dataPoints) {
        DataSet set = store.get(series);
        if (set == null) {
            set = new DataSet(dataPoints);
            store.put(series, set);
        } else {
            set.addAll(dataPoints);
        }
    }
654702
public void connecDataSet(IntermediateDataSet dataSet) {
		if (dataSet == null) {
			throw new NullPointerException();
		}
		if (this.source != null) {
			throw new IllegalStateException("The edge is already connected.");
		}
		if (!dataSet.getId().equals(sourceId)) {
			throw new IllegalArgumentException("The data set to connect does not match the sourceId.");
		}
		
		this.source = dataSet;
	}
687823
def dataset_update_method(dataset, other):
    
    from .dataset import Dataset
    from .dataarray import DataArray

    if not isinstance(other, Dataset):
        other = OrderedDict(other)
        for key, value in other.items():
            if isinstance(value, DataArray):
                # drop conflicting coordinates
                coord_names = [c for c in value.coords
                               if c not in value.dims and c in dataset.coords]
                if coord_names:
                    other[key] = value.drop(coord_names)

    return merge_core([dataset, other], priority_arg=1,
                      indexes=dataset.indexes)
983672
public void send(StDatapoint datapoint) {
    StDatapointValidator.validate(datapoint);
    sender.send(Collections.singletonList(datapoint));
  }
1219386
public static BatchCSVRecord fromDataSet(DataSet dataSet) {
        BatchCSVRecord batchCSVRecord = new BatchCSVRecord();
        for (int i = 0; i < dataSet.numExamples(); i++) {
            batchCSVRecord.add(SingleCSVRecord.fromRow(dataSet.get(i)));
        }

        return batchCSVRecord;
    }
943417
public static List<String> getLabels(Set dataSet) {
        char[] c = getLabelsArray(dataSet);
        List<String> l = new ArrayList<>(c.length);
        for (char c2 : c) {
            l.add(String.valueOf(c2));
        }
        return l;
    }
1258856
public Object get(int dataSet) throws SerializationException {
		Object result = null;
		for (Iterator<DataSet> i = dataSets.iterator(); i.hasNext();) {
			DataSet ds = i.next();
			DataSetInfo info = ds.getInfo();
			if (info.getDataSetNumber() == dataSet) {
				result = getData(ds);
				break;
			}
		}
		return result;
	}
456993
public void addData(LofPoint addedPoint)
    {
        this.dataIdList.add(addedPoint.getDataId());
        this.dataMap.put(addedPoint.getDataId(), addedPoint);
    }
1233692
public Long updateDatasetExpiration(DatasetInfo dataset) {
    // [START bigquery_update_dataset_expiration]
    Long beforeExpiration = dataset.getDefaultTableLifetime();

    Long oneDayMilliseconds = 24 * 60 * 60 * 1000L;
    DatasetInfo.Builder builder = dataset.toBuilder();
    builder.setDefaultTableLifetime(oneDayMilliseconds);
    bigquery.update(builder.build()); // API request.
    // [END bigquery_update_dataset_expiration]

    return beforeExpiration;
  }
1014766
def _get_coordinates_for_dataset_key(self, dsid):
        
        coords = super(VIIRSSDRReader, self)._get_coordinates_for_dataset_key(dsid)
        for c_id in coords:
            c_info = self.ids[c_id]  # c_info['dataset_groups'] should be a list of 2 elements
            self._get_file_handlers(c_id)
            if len(c_info['dataset_groups']) == 1:  # filtering already done
                continue
            try:
                req_geo, rem_geo = self._get_req_rem_geo(c_info)
            except ValueError:  # DNB
                continue

            # check the dataset file for the geolocation filename
            geo_filenames = self._load_from_geo_ref(dsid)
            if not geo_filenames:
                c_info['dataset_groups'] = [rem_geo]
            else:
                # concatenate all values
                new_fhs = sum(self.create_filehandlers(geo_filenames).values(), [])
                desired, other = split_desired_other(new_fhs, req_geo, rem_geo)
                if desired:
                    c_info['dataset_groups'].remove(rem_geo)
                else:
                    c_info['dataset_groups'].remove(req_geo)

        return coords
1292383
public static List<String> getAlterOriginalPartitionLocationQueries(PurgeableHivePartitionDataset dataset) {
    List<String> queries = new ArrayList<>();
    queries.add(getUseDbQuery(dataset.getDbName()));
    String partitionSpecString = PartitionUtils.getPartitionSpecString(dataset.getSpec());
    queries.add(
        getAlterTableLocationQuery(dataset.getTableName(), partitionSpecString, dataset.getStagingPartitionLocation()));
    queries.add(getUpdatePartitionMetadataQuery(dataset.getDbName(), dataset.getTableName(), partitionSpecString));
    return queries;
  }