This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
long blockTimestamp = calculateBlockTimestamp(dataPoint); | |
String cacheKey = toCacheKey(dataPoint.getMetricKey(), blockTimestamp); | |
byte[] data = storageWrapper.get(cacheKey); | |
MutableCompressor compressor; | |
if (data == null) { | |
ByteBufferBitOutput output = new ByteBufferBitOutput(128); | |
compressor = new MutableCompressor(blockTimestamp, output); | |
} else { | |
compressor = new MutableCompressor(blockTimestamp, ByteBuffer.wrap(data)); | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Rozciaganie | |
Test skokowego | |
https://www.facebook.com/runnerprojectteam/videos/198188927757582/?t=5 | |
Biodrowo-ledzwiowy | |
niemal każdy biegacz wie jak ważne jest posiadanie elastycznego mięśnia biodrowo-lędźwiowego. dlatego dużo pracuje nad jego mobilnością - I BARDZO DOBRZE, lecz pamiętać należy, że gdy mięsień jest skrócony to jest słaby. | |
Zatem poza uelastycznianiem biodrowo-lędźwiowego warto go wzmacniać. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import java.io.BufferedReader; | |
import java.io.FileReader; | |
import java.io.IOException; | |
import java.net.URI; | |
import java.util.ArrayList; | |
import java.util.HashSet; | |
import java.util.List; | |
import java.util.Set; | |
import java.util.StringTokenizer; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
CloseableHttpAsyncClient client = HttpAsyncClientBuilder.create().build(); | |
client.start(); | |
CompletableFuture<String> body = new CompletableFuture<>(); | |
System.out.println("sending"); | |
Stopwatch stopwatch = Stopwatch.createStarted(); | |
client.execute(new HttpGet("http://gazeta.pl"), new FutureCallback<HttpResponse>() { | |
@Override | |
public void completed(HttpResponse httpResponse) { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
FELIETONU NIE BĘDZIE | |
Szanowna Redakcjo! | |
Otóż oświadczam, że felietonu do bieżącego numeru nie napiszę. I co mi zrobicie? W nosie mam wasze terminy rodem z III RP. Właśnie wstałem z kolan, zrywając okowy postkomuszej redakcyjnej opresji, przy okazji waląc solidnie głową w parapet, więc jestem co prawda bardzo dumny i wzmożony, ale trochę zamroczony. Mam prawo do suwerennej autodestrukcji i żadne resortowe paniczyki nie będą mi mówić, co mam robić. To po pierwsze primo. | |
Po drugie, jak słusznie zauważyła profesor Pawłowicz, obecna opozycja jest faszystowska, a ja dodam, że najbardziej faszystowskie są opozycyjne media, w których nazistowską palmę pierwszeństwa dzierżycie wy tam w „Newsweeku”. Kto to widział, żeby z powodu długiego weekendu przyspieszać terminy o dobę z okładem? Jeśli to nie jest faszyzm, to ja już naprawdę nie wiem, co nim jest. Żeby choć to przyspieszenie wynikało z pragnienia całej redakcji wysłuchania w należnym skupieniu mowy Pana Prezydenta z okazji 3 Maja, w której to mowie na pewno znajdz |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package org.kairosdb.datastore.cql.tables; | |
import com.datastax.driver.core.ResultSet; | |
import com.datastax.driver.core.ResultSetFuture; | |
import com.google.common.util.concurrent.FutureCallback; | |
import org.slf4j.Logger; | |
import org.slf4j.LoggerFactory; | |
import javax.annotation.Nullable; | |
import java.io.IOException; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import com.fasterxml.jackson.databind.util.ByteBufferBackedOutputStream; | |
import com.google.common.base.Stopwatch; | |
import com.google.common.hash.BloomFilter; | |
import com.google.common.hash.Funnel; | |
import com.google.common.hash.Funnels; | |
import com.google.common.io.ByteArrayDataOutput; | |
import com.google.common.io.ByteStreams; | |
import java.io.ByteArrayInputStream; | |
import java.io.IOException; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import com.google.common.base.Stopwatch; | |
import org.apache.avro.Schema; | |
import org.apache.avro.SchemaBuilder; | |
import org.apache.avro.file.DataFileReader; | |
import org.apache.avro.file.DataFileWriter; | |
import org.apache.avro.generic.GenericData; | |
import org.apache.avro.generic.GenericDatumReader; | |
import org.apache.avro.generic.GenericDatumWriter; | |
import org.apache.avro.generic.GenericRecord; | |
import org.apache.avro.io.DatumReader; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import com.google.common.base.Stopwatch; | |
import org.apache.avro.Schema; | |
import org.apache.avro.SchemaBuilder; | |
import org.apache.avro.file.DataFileReader; | |
import org.apache.avro.file.DataFileWriter; | |
import org.apache.avro.generic.GenericData; | |
import org.apache.avro.generic.GenericDatumReader; | |
import org.apache.avro.generic.GenericDatumWriter; | |
import org.apache.avro.generic.GenericRecord; | |
import org.apache.avro.io.DatumReader; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Override | |
public void addCallback(KairosTableRow<C, V, K> tableRow, FutureCallback<ResultSet> callback) | |
{ | |
bufferCounter.incrementAndGet(); | |
executorService.submit(() -> { | |
bufferCounter.decrementAndGet(); | |
baseKairosTableRepository.addCallback(tableRow, new FutureCallback<ResultSet>() | |
{ | |
@Override | |
public void onSuccess(@Nullable ResultSet result) |
NewerOlder