org.openstreetmap.osmosis.core.domain.v0_6.Entity.getType()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(6.9k)|赞(0)|评价(0)|浏览(93)

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

Entity.getType介绍

[英]Returns the specific data type represented by this entity.
[中]返回此实体表示的特定数据类型。

代码示例

代码示例来源:origin: mapsforge/mapsforge

} catch (NumberFormatException e) {
  LOGGER.finest("could not parse layer information to byte type: " + tag.getValue()
      + "\t entity-id: " + entity.getId() + "\tentity-type: " + entity.getType().name());
      + "\t entity-id: " + entity.getId() + "\tentity-type: " + entity.getType().name());

代码示例来源:origin: mapsforge/mapsforge

LOGGER.finest("Processing entity: " + entity.toString());
switch (entity.getType()) {
  case Node:
    Node node = (Node) entity;

代码示例来源:origin: mapsforge/mapsforge

Entity entity = entityContainer.getEntity();
switch (entity.getType()) {
  case Bound:
    Bound bound = (Bound) entity;

代码示例来源:origin: openstreetmap/osmosis

/**
   * {@inheritDoc}
   */
  public int compare(Entity o1, Entity o2) {
    // Perform a type comparison.
    return o1.getType().compareTo(o2.getType());
  }
}

代码示例来源:origin: org.openstreetmap.osmosis/osmosis-core

/**
   * {@inheritDoc}
   */
  public int compare(Entity o1, Entity o2) {
    // Perform a type comparison.
    return o1.getType().compareTo(o2.getType());
  }
}

代码示例来源:origin: ncolomer/elasticsearch-osmosis-plugin

public synchronized void submit(Entity entity) {
  if (!entity.getType().equals(lastEntityType.getAndSet(entity.getType()))) {
    notifyNewType(entity.getType());
  }
  try {
    while (!taskQueue.offer(entity, POLL_INTERVAL, TimeUnit.MILLISECONDS));
  } catch (InterruptedException e) {
    throw new IllegalStateException("InterruptedException caught", e);
  }
}

代码示例来源:origin: adrianulbona/osm-parquetizer

@Override
public void process(EntityContainer entityContainer) {
  try {
    if (this.entityType == entityContainer.getEntity().getType()) {
      final T entity = (T) entityContainer.getEntity();
      if (filters.stream().noneMatch(filter -> filter.test(entity))) {
        writer.write(entity);
      }
    }
  } catch (IOException e) {
    throw new RuntimeException("Unable to write entity", e);
  }
}

代码示例来源:origin: ncolomer/elasticsearch-osmosis-plugin

@Override
public void process(EntityContainer entityContainer) {
  Entity entity = entityContainer.getEntity();
  EntityType type = entity.getType();
  workerPool.submit(entity);
  entityCounter.increment(type);
}

代码示例来源:origin: org.openstreetmap.osmosis/osmosis-apidb

private void assertEntityHasTimestamp(Entity entity) {
  if (entity.getTimestamp() == null) {
    throw new OsmosisRuntimeException(
        entity.getType().toString() + " " + entity.getId() + " does not have a timestamp set.");
  }
}

代码示例来源:origin: org.openstreetmap.osmosis/osmosis-core

/**
 * {@inheritDoc}
 */
public void process(EntityContainer entityContainer) {
  Entity entity;
  
  entity = entityContainer.getEntity();
  
  if (progressTracker.updateRequired()) {
    LOG.info(
        prefix
        + "Processing " + entity.getType() + " " + entity.getId() + ", "
        + progressTracker.getObjectsPerSecond() + " objects/second.");
  }
  
  sink.process(entityContainer);
}

代码示例来源:origin: openstreetmap/osmosis

private void assertEntityHasTimestamp(Entity entity) {
  if (entity.getTimestamp() == null) {
    throw new OsmosisRuntimeException(
        entity.getType().toString() + " " + entity.getId() + " does not have a timestamp set.");
  }
}

代码示例来源:origin: openstreetmap/osmosis

private void assertEntityHasTimestamp(Entity entity) {
  if (entity.getTimestamp() == null) {
    throw new OsmosisRuntimeException(
        entity.getType().toString() + " " + entity.getId() + " does not have a timestamp set.");
  }
}

代码示例来源:origin: openstreetmap/osmosis

/**
 * {@inheritDoc}
 */
public void process(EntityContainer entityContainer) {
  Entity entity;
  
  entity = entityContainer.getEntity();
  
  if (progressTracker.updateRequired()) {
    LOG.info(
        prefix
        + "Processing " + entity.getType() + " " + entity.getId() + ", "
        + progressTracker.getObjectsPerSecond() + " objects/second.");
  }
  
  sink.process(entityContainer);
}

代码示例来源:origin: org.openstreetmap.osmosis/osmosis-apidb

private void assertEntityHasTimestamp(Entity entity) {
  if (entity.getTimestamp() == null) {
    throw new OsmosisRuntimeException(
        entity.getType().toString() + " " + entity.getId() + " does not have a timestamp set.");
  }
}

代码示例来源:origin: openstreetmap/osmosis

/**
 * Performs any validation and pre-processing required for all entity types.
 */
private void processEntityPrerequisites(Entity entity) {
  // We can't write an entity with a null timestamp.
  if (entity.getTimestamp() == null) {
    throw new OsmosisRuntimeException("Entity(" + entity.getType()
        + ") " + entity.getId() + " does not have a timestamp set.");
  }
  
  // Process the user data.
  writeUser(entity.getUser());
}

代码示例来源:origin: openstreetmap/osmosis

/**
 * Performs any validation and pre-processing required for all entity types.
 */
private void processEntityPrerequisites(Entity entity) {
  // We can't write an entity with a null timestamp.
  if (entity.getTimestamp() == null) {
    throw new OsmosisRuntimeException("Entity(" + entity.getType()
        + ") " + entity.getId() + " does not have a timestamp set.");
  }
  
  // Process the user data.
  writeUser(entity.getUser());
}

代码示例来源:origin: openstreetmap/osmosis

/**
 * {@inheritDoc}
 */
public void process(ChangeContainer changeContainer) {
  Entity entity;
  ChangeAction action;
  
  entity = changeContainer.getEntityContainer().getEntity();
  action = changeContainer.getAction();
  
  if (progressTracker.updateRequired()) {
    LOG.info(
        prefix 
        + "Processing " + entity.getType() + " " + entity.getId() + " with action " + action + ", "
        + progressTracker.getObjectsPerSecond() + " objects/second.");
  }
  
  changeSink.process(changeContainer);
}

代码示例来源:origin: org.openstreetmap.osmosis/osmosis-core

private void processFirstEntity(EntityContainer entityContainer) {
  if (entityContainer.getEntity().getType() == EntityType.Bound) {
    if (newBound == null) {
      // Just returning won't pass the entity downstream
      return;
    } else {
      sink.process(new BoundContainer(newBound));
    }
  } else {
    if (newBound != null) {
      sink.process(new BoundContainer(newBound));
    }
    sink.process(entityContainer);
  }
}

代码示例来源:origin: openstreetmap/osmosis

/**
 * Tests the bound removal when there is no bound upstream.
 */
@Test
public void removeNoBoundTest() {
  SinkEntityInspector inspector = new SinkEntityInspector();
  BoundSetter setter = new BoundSetter(null);
  setter.setSink(inspector);
  setter.process(new NodeContainer(new Node(
      new CommonEntityData(1, 1, new Date(), OsmUser.NONE, 1), 1, 1)));
  setter.complete();
  setter.close();
  
  EntityContainer ec = inspector.getProcessedEntities().iterator().next();
  Assert.assertEquals(EntityType.Node, ec.getEntity().getType());
}

代码示例来源:origin: openstreetmap/osmosis

/**
 * Tests the bound removal.
 */
@Test
public void removeExistingBoundTest() {
  SinkEntityInspector inspector = new SinkEntityInspector();
  BoundSetter setter = new BoundSetter(null);
  setter.setSink(inspector);
  setter.process(new BoundContainer(new Bound("Test")));
  setter.process(new NodeContainer(new Node(
      new CommonEntityData(1, 1, new Date(), OsmUser.NONE, 1), 1, 1)));
  setter.complete();
  setter.close();
  
  EntityContainer ec = inspector.getProcessedEntities().iterator().next();
  Assert.assertEquals(EntityType.Node, ec.getEntity().getType());
}

相关文章