本文整理了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
[英]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());
}
内容来源于网络,如有侵权,请联系作者删除!