Skip to content

Instantly share code, notes, and snippets.

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));
}
@gmucha
gmucha / cwiczenia.txt
Created December 14, 2018 08:07
Rehab ćwiczenia
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ć.
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;
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) {
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
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;
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;
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;
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;
@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)