floor ( ) 源码实例Demo-ICode联盟

源代码1 项目： flink 文件： SessionWindowAssigner.java

@Override
public void mergeWindows(TimeWindow newWindow, NavigableSet<TimeWindow> sortedWindows, MergeCallback<TimeWindow> callback) {
	TimeWindow ceiling = sortedWindows.ceiling(newWindow);
	TimeWindow floor = sortedWindows.floor(newWindow);

	Collection<TimeWindow> mergedWindows = new HashSet<>();
	TimeWindow mergeResult = newWindow;
	if (ceiling != null) {
		mergeResult = mergeWindow(mergeResult, ceiling, mergedWindows);
	}
	if (floor != null) {
		mergeResult = mergeWindow(mergeResult, floor, mergedWindows);
	}
	if (!mergedWindows.isEmpty()) {
		// merge happens, add newWindow into the collection as well.
		mergedWindows.add(newWindow);
		callback.merge(mergeResult, mergedWindows);
	}
}

源代码2 项目： kylin-on-parquet-v2 文件： BadQueryHistoryManagerTest.java

@Test
public void testUpdateEntryToProject() throws IOException {
    KylinConfig kylinConfig = getTestConfig();
    BadQueryHistoryManager manager = BadQueryHistoryManager.getInstance(kylinConfig);

    String queryId = RandomUtil.randomUUID().toString();
    manager.upsertEntryToProject(
            new BadQueryEntry("sql", "adj", 1459362239000L, 100, "server", "t-0", "user", queryId, "cube"),
            "default");
    BadQueryHistory history = manager.upsertEntryToProject(
            new BadQueryEntry("sql", "adj2", 1459362239000L, 120, "server2", "t-1", "user", queryId, "cube"), "default");

    NavigableSet<BadQueryEntry> entries = history.getEntries();
    BadQueryEntry newEntry = entries
            .floor(new BadQueryEntry("sql", "adj2", 1459362239000L, 120, "server2", "t-1", "user", queryId, "cube"));
    System.out.println(newEntry);
    assertEquals("adj2", newEntry.getAdj());
    assertEquals("server2", newEntry.getServer());
    assertEquals("t-1", newEntry.getThread());
    assertEquals("user", newEntry.getUser());
    assertEquals(120, (int) newEntry.getRunningSec());
}

源代码3 项目： tracecompass 文件： ThreadStatusDataProvider.java

private static @NonNull ITimeGraphState createTimeGraphState(ITmfStateInterval interval, NavigableSet<ITmfStateInterval> syscalls) {
    long startTime = interval.getStartTime();
    long duration = interval.getEndTime() - startTime + 1;
    Object status = interval.getValue();
    if (status instanceof Integer) {
        int s = (int) status;
        if (s == StateValues.PROCESS_STATUS_RUN_SYSCALL) {
            // intervals are sorted by start time
            ITmfStateInterval syscall = syscalls.floor(new TmfStateInterval(startTime, startTime + 1, 0, 0));

            if (syscall != null) {
                Object value = syscall.getValue();
                if (value instanceof String) {
                    return new TimeGraphState(startTime, duration, String.valueOf(value), getElementStyle(s));
                }
            }
        }
        return new TimeGraphState(startTime, duration, null, getElementStyle(s));
    }
    return new TimeGraphState(startTime, duration, Integer.MIN_VALUE);
}

源代码4 项目： kylin 文件： BadQueryHistoryManagerTest.java

@Test
public void testUpdateEntryToProject() throws IOException {
    KylinConfig kylinConfig = getTestConfig();
    BadQueryHistoryManager manager = BadQueryHistoryManager.getInstance(kylinConfig);

    String queryId = RandomUtil.randomUUID().toString();
    manager.upsertEntryToProject(
            new BadQueryEntry("sql", "adj", 1459362239000L, 100, "server", "t-0", "user", queryId, "cube"),
            "default");
    BadQueryHistory history = manager.upsertEntryToProject(
            new BadQueryEntry("sql", "adj2", 1459362239000L, 120, "server2", "t-1", "user", queryId, "cube"), "default");

    NavigableSet<BadQueryEntry> entries = history.getEntries();
    BadQueryEntry newEntry = entries
            .floor(new BadQueryEntry("sql", "adj2", 1459362239000L, 120, "server2", "t-1", "user", queryId, "cube"));
    System.out.println(newEntry);
    assertEquals("adj2", newEntry.getAdj());
    assertEquals("server2", newEntry.getServer());
    assertEquals("t-1", newEntry.getThread());
    assertEquals("user", newEntry.getUser());
    assertEquals(120, (int) newEntry.getRunningSec());
}

源代码5 项目： flink 文件： SessionWindowAssigner.java

@Override
public void mergeWindows(TimeWindow newWindow, NavigableSet<TimeWindow> sortedWindows, MergeCallback<TimeWindow> callback) {
	TimeWindow ceiling = sortedWindows.ceiling(newWindow);
	TimeWindow floor = sortedWindows.floor(newWindow);

	Collection<TimeWindow> mergedWindows = new HashSet<>();
	TimeWindow mergeResult = newWindow;
	if (ceiling != null) {
		mergeResult = mergeWindow(mergeResult, ceiling, mergedWindows);
	}
	if (floor != null) {
		mergeResult = mergeWindow(mergeResult, floor, mergedWindows);
	}
	if (!mergedWindows.isEmpty()) {
		// merge happens, add newWindow into the collection as well.
		mergedWindows.add(newWindow);
		callback.merge(mergeResult, mergedWindows);
	}
}

源代码6 项目： openjdk-jdk9 文件： TreeSubSetTest.java

/**
 * floor returns preceding element
 */
public void testFloor() {
    NavigableSet q = set5();
    Object e1 = q.floor(three);
    assertEquals(three, e1);

    Object e2 = q.floor(six);
    assertEquals(five, e2);

    Object e3 = q.floor(one);
    assertEquals(one, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码7 项目： openjdk-jdk9 文件： TreeSubSetTest.java

/**
 * floor returns preceding element
 */
public void testDescendingFloor() {
    NavigableSet q = dset5();
    Object e1 = q.floor(m3);
    assertEquals(m3, e1);

    Object e2 = q.floor(m6);
    assertEquals(m5, e2);

    Object e3 = q.floor(m1);
    assertEquals(m1, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码8 项目： openjdk-jdk9 文件： ConcurrentSkipListSubSetTest.java

/**
 * floor returns preceding element
 */
public void testFloor() {
    NavigableSet q = set5();
    Object e1 = q.floor(three);
    assertEquals(three, e1);

    Object e2 = q.floor(six);
    assertEquals(five, e2);

    Object e3 = q.floor(one);
    assertEquals(one, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码9 项目： openjdk-jdk9 文件： ConcurrentSkipListSubSetTest.java

/**
 * floor returns preceding element
 */
public void testDescendingFloor() {
    NavigableSet q = dset5();
    Object e1 = q.floor(m3);
    assertEquals(m3, e1);

    Object e2 = q.floor(m6);
    assertEquals(m5, e2);

    Object e3 = q.floor(m1);
    assertEquals(m1, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码10 项目： scava 文件： BTreeSet2Test.java

/**
 * floor returns preceding element
 */
public void testFloor() {
    NavigableSet q = set5();
    Object e1 = q.floor(three);
    assertEquals(three, e1);

    Object e2 = q.floor(six);
    assertEquals(five, e2);

    Object e3 = q.floor(one);
    assertEquals(one, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码11 项目： scava 文件： BTreeMapSubSetTest.java

/**
 * floor returns preceding element
 */
public void testFloor() {
    NavigableSet q = set5();
    Object e1 = q.floor(three);
    assertEquals(three, e1);

    Object e2 = q.floor(six);
    assertEquals(five, e2);

    Object e3 = q.floor(one);
    assertEquals(one, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码12 项目： gemfirexd-oss 文件： ConcurrentSkipListSubSetJUnitTest.java

/**
 * floor returns preceding element
 */
public void testFloor() {
    NavigableSet q = set5();
    Object e1 = q.floor(three);
    assertEquals(three, e1);

    Object e2 = q.floor(six);
    assertEquals(five, e2);

    Object e3 = q.floor(one);
    assertEquals(one, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码13 项目： gemfirexd-oss 文件： ConcurrentSkipListSubSetJUnitTest.java

/**
 * floor returns preceding element
 */
public void testDescendingFloor() {
    NavigableSet q = dset5();
    Object e1 = q.floor(m3);
    assertEquals(m3, e1);

    Object e2 = q.floor(m6);
    assertEquals(m5, e2);

    Object e3 = q.floor(m1);
    assertEquals(m1, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码14 项目： gemfirexd-oss 文件： ConcurrentSkipListSubSetJUnitTest.java

/**
 * floor returns preceding element
 */
public void testFloor() {
    NavigableSet q = set5();
    Object e1 = q.floor(three);
    assertEquals(three, e1);

    Object e2 = q.floor(six);
    assertEquals(five, e2);

    Object e3 = q.floor(one);
    assertEquals(one, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码15 项目： gemfirexd-oss 文件： ConcurrentSkipListSubSetJUnitTest.java

/**
 * floor returns preceding element
 */
public void testDescendingFloor() {
    NavigableSet q = dset5();
    Object e1 = q.floor(m3);
    assertEquals(m3, e1);

    Object e2 = q.floor(m6);
    assertEquals(m5, e2);

    Object e3 = q.floor(m1);
    assertEquals(m1, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码16 项目： rtg-tools 文件： PopulationVariantGenerator.java

private static boolean validPos(PopulationVariant var, NavigableSet<PopulationVariant> set) {
  final int candStart = var.getStart();
  final int candEnd = var.getEnd();
  final PopulationVariant floor = set.floor(var);
  final PopulationVariant higher = set.higher(var);
  if (floor != null && var.getSequenceId() == floor.getSequenceId() && floor.getEnd() > candStart) {
    return false;
  }
  if (higher != null && var.getSequenceId() == higher.getSequenceId() && candEnd > higher.getStart()) {
    return false;
  }
  return true;
}

源代码17 项目： j2objc 文件： TreeSubSetTest.java

/**
 * floor returns preceding element
 */
public void testFloor() {
    NavigableSet q = set5();
    Object e1 = q.floor(three);
    assertEquals(three, e1);

    Object e2 = q.floor(six);
    assertEquals(five, e2);

    Object e3 = q.floor(one);
    assertEquals(one, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码18 项目： j2objc 文件： TreeSubSetTest.java

/**
 * floor returns preceding element
 */
public void testDescendingFloor() {
    NavigableSet q = dset5();
    Object e1 = q.floor(m3);
    assertEquals(m3, e1);

    Object e2 = q.floor(m6);
    assertEquals(m5, e2);

    Object e3 = q.floor(m1);
    assertEquals(m1, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码19 项目： j2objc 文件： ConcurrentSkipListSubSetTest.java

/**
 * floor returns preceding element
 */
public void testFloor() {
    NavigableSet q = set5();
    Object e1 = q.floor(three);
    assertEquals(three, e1);

    Object e2 = q.floor(six);
    assertEquals(five, e2);

    Object e3 = q.floor(one);
    assertEquals(one, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

源代码20 项目： j2objc 文件： ConcurrentSkipListSubSetTest.java

/**
 * floor returns preceding element
 */
public void testDescendingFloor() {
    NavigableSet q = dset5();
    Object e1 = q.floor(m3);
    assertEquals(m3, e1);

    Object e2 = q.floor(m6);
    assertEquals(m5, e2);

    Object e3 = q.floor(m1);
    assertEquals(m1, e3);

    Object e4 = q.floor(zero);
    assertNull(e4);
}

java.util.NavigableSet# floor ( ) 源码实例Demo